package org.myorg.kafka2mysql.demo;


import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.myorg.kafka2mysql.demo.MysqlDatasource;

public class MysqlDsFlinkApp {

	public static void main(String[] args) throws Exception {
		final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
		env.addSource(new MysqlDatasource()).print();
		env.execute("Flink add mysql datasource");
	}
}
